46aa0b2c822fc19b6e1c2e4208d71d1acae6eeb9,enterprise/main/java/org/neo4j/kernel/ha/MasterImpl.java,MasterImpl,packResponse,#SlaveContext#T#Predicate#,337
Before Change
try
{
TransactionStreams streams = new TransactionStreams();
for ( Map.Entry<String, Long> slaveEntry :
context.lastAppliedTransactions().entrySet() )
{
String resourceName = slaveEntry.getKey();
XaDataSource dataSource = getConfig().getTxModule()
.getXaDataSourceManager().getXaDataSource( resourceName );
long masterLastTx = dataSource.getLastCommittedTxId();
long slaveLastTx = slaveEntry.getValue();
Collection<ReadableByteChannel> channels = new ArrayList<ReadableByteChannel>();
for ( long txId = slaveLastTx+1; txId <= masterLastTx; txId++ )
{
if ( filter.accept( txId ) )
{
channels.add( dataSource.getCommittedTransaction( txId ) );
}
}
streams.add( slaveEntry.getKey(), new TransactionStream( channels ) );
}
return new Response<T>( response, streams );
}
After Change
try
{
TransactionStreams streams = new TransactionStreams();
for ( Pair<String, Long> txEntry : context.lastAppliedTransactions() )
{
String resourceName = txEntry.first();
XaDataSource dataSource = graphDbConfig.getTxModule().getXaDataSourceManager()
.getXaDataSource( resourceName );
long masterLastTx = dataSource.getLastCommittedTxId();
Collection<ReadableByteChannel> channels = new ArrayList<ReadableByteChannel>();
for ( long txId = txEntry.other()+1; txId <= masterLastTx; txId++ )
{
if ( filter.accept( txId ) )
{